google.golang.org/grpc.csAttempt.transportStream (field)

35 uses

	google.golang.org/grpc (current package)
		rpc_util.go#L285: 	*o.HeaderAddr, _ = attempt.transportStream.Header()
		rpc_util.go#L307: 	*o.TrailerAddr = attempt.transportStream.Trailer()
		rpc_util.go#L329: 	if x, ok := peer.FromContext(attempt.transportStream.Context()); ok {
		stream.go#L567: 	a.transportStream = s
		stream.go#L640: 	transportStream *transport.ClientStream
		stream.go#L693: 	if a.transportStream == nil && a.allowTransparentRetry {
		stream.go#L698: 	if a.transportStream != nil {
		stream.go#L699: 		<-a.transportStream.Done()
		stream.go#L700: 		unprocessed = a.transportStream.Unprocessed()
		stream.go#L712: 	if a.transportStream != nil {
		stream.go#L713: 		if !a.transportStream.TrailersOnly() {
		stream.go#L719: 		sps := a.transportStream.Trailer()["grpc-retry-pushback-ms"]
		stream.go#L736: 	if a.transportStream != nil {
		stream.go#L737: 		code = a.transportStream.Status().Code()
		stream.go#L810: 	if cs.attempt.transportStream != nil {
		stream.go#L811: 		return cs.attempt.transportStream.Context()
		stream.go#L848: 			<-a.transportStream.Done()
		stream.go#L850: 		if err == nil || (err == io.EOF && a.transportStream.Status().Code() == codes.OK) {
		stream.go#L866: 		m, err = a.transportStream.Header()
		stream.go#L910: 	if cs.attempt.transportStream == nil {
		stream.go#L913: 	return cs.attempt.transportStream.Trailer()
		stream.go#L1046: 		a.transportStream.Write(nil, nil, &transport.WriteOptions{Last: true})
		stream.go#L1084: 		if cs.attempt.transportStream != nil {
		stream.go#L1132: 	if err := a.transportStream.Write(hdr, payld, &transport.WriteOptions{Last: !cs.desc.ClientStreams}); err != nil {
		stream.go#L1156: 		if ct := a.transportStream.RecvCompress(); ct != "" && ct != encoding.Identity {
		stream.go#L1174: 	if err := recv(&a.parser, cs.codec, a.transportStream, a.decompressorV0, m, *cs.callInfo.maxReceiveMessageSize, payInfo, a.decompressorV1, false); err != nil {
		stream.go#L1176: 			if statusErr := a.transportStream.Status().Err(); statusErr != nil {
		stream.go#L1212: 	if err := recv(&a.parser, cs.codec, a.transportStream, a.decompressorV0, m, *cs.callInfo.maxReceiveMessageSize, nil, a.decompressorV1, false); err == io.EOF {
		stream.go#L1213: 		return a.transportStream.Status().Err() // non-server streaming Recv returns nil on success
		stream.go#L1232: 	if a.transportStream != nil {
		stream.go#L1233: 		a.transportStream.Close(err)
		stream.go#L1234: 		tr = a.transportStream.Trailer()
		stream.go#L1239: 		if a.transportStream != nil {
		stream.go#L1240: 			br = a.transportStream.BytesReceived()
		stream.go#L1245: 			BytesSent:     a.transportStream != nil,

The pages are generated with Golds v0.8.4. (GOOS=linux GOARCH=amd64)